package com.jml;//package com.jml;
//
//import com.jml.service.MemberService;
//import org.apache.kafka.clients.consumer.ConsumerRecord;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
//@Component
//public class Consumer {
//    private static final org.slf4j.Logger log = org.slf4j.LoggerFactory.getLogger(MemberService.class);
//    @KafkaListener(topics = "jml-log")
//    public void receive(ConsumerRecord<?, ?> consumer) {
//        log.info(">topic名称:{},,key:{},分区位置:{},offset{},value:{}<",
//                consumer.topic(), consumer.key(), consumer.partition(), consumer.offset(), consumer.value());
//    }
//}
